<?php
namespace app\job;
use think\queue\Job;

class Message {

    public function sendSms(Job $job, $data){
        sleep(3);
//        dump('CMD:sendSms' . $job->attempts());
//        dump($data);
        $this->log('Message/sendSms',var_export($data,true));
        $job->delete();
        return;
        // 重复3次都没结束则强制删除任务
//        if ($job->attempts() > 3) {
//            $job->delete();
//            return;
//        }else{
//            // 延迟10秒钟再执行一次这个任务
//            $job->release(1);
//        }
    }

    public function sendEmail(Job $job, $data){
        dump('sendEmail');
        dump($data);
        $job->delete();
        return;
    }

    public function failed($data){


    }
    //日志
    private function log($cmd,$str,$filename='MessageQueue.log') {
        $file= dirname(dirname(__DIR__)) . '/log/' . $filename;
        create_dir($file);
        $text='[Time ' . date('Y-m-d H:i:s') ."]\ncmd:" .$cmd. "\n" .$str. "\n---END---" . "\n";
        if(false !== fopen($file,'a+')){
            file_put_contents($file,$text,FILE_APPEND);
        }else{
            echo '创建失败';
        }
    }


}
